//package com.wwy.consumer;
//
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
//import com.rabbitmq.client.Channel;
//
//@RabbitListener(queues = "topic_queue_one")
//public class MyMessageListener implements ChannelAwareMessageListener {
//
//    @Override
//    public void onMessage(Message message, Channel channel) throws Exception {
//        try {
//            // 手动处理消息
//            processMessage(message);
//            // 手动确认消息
//            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
//        } catch (Exception e) {
//            // 发生异常时，可选择是否重新入队或者丢弃消息
//            // 重新入队：channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
//            // 丢弃消息：channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
//            // 此处简单起见，直接重新入队
//            channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
//        }
//    }
//
//    private void processMessage(Message message) {
//        // 处理消息的业务逻辑
//    }
//}
